# from crawler.connection import send_reply
#
# __all__ = ['ReplyRocketMQPipeline']
#
#
# class ReplyRocketMQPipeline(object):
#
#     def process_item(self, item, spider):
#         task = item['origin']
#         task.update({
#             'latestStatusTime': item.get('ATD', '')}
#         )
#         status = 1
#         error_msg = ""
#         data_id = item['dataId']
#         # send_reply(task, status, error_msg, data_id)
#         return item
